5940b3c72cb37ed88caa961aad57cff450936e35,advanced/main/java/org/neo4j/kernel/ha/CommunicationProtocol.java,CommunicationProtocol,handleRequest,#Master#ChannelBuffer#Channel#MasterServer#,218
Before Change
if ( type.includesSlaveContext() )
{
context = readSlaveContext( buffer );
server.mapSlave( channel, context );
}
Response<?> response = type.caller.callMaster( realMaster, context, buffer );
ChannelBuffer targetBuffer = ChannelBuffers.dynamicBuffer();
After Change
{
context = readSlaveContext( buffer );
}
Pair<ChannelBuffer, ByteBuffer> targetBuffers = server.mapSlave( channel, context );
targetBuffers.first().clear();
Response<?> response = type.caller.callMaster( realMaster, context, buffer );
type.serializer.write( response.response(), targetBuffers.first() );
if ( type.includesSlaveContext() )
{
writeTransactionStreams( response.transactions(), targetBuffers.first(), targetBuffers.other() );
}
if ( type == RequestType.FINISH || type == RequestType.PULL_UPDATES )
{
server.unmapSlave( channel, context );
}
return targetBuffers.first();
}
private static <T> void writeTransactionStreams( TransactionStreams txStreams,